c8a8691f21832da23f916fa0e1b0c57a8e8ed133,enterprise/main/java/org/neo4j/kernel/ha/SlaveTxIdGenerator.java,SlaveTxIdGenerator,generate,#XaDataSource#number#,50
Before Change
Response<Long> response = broker.getMaster().commitSingleResourceTransaction(
receiver.getSlaveContext( eventIdentifier ),
dataSource.getName(), new TransactionStream( Arrays.asList(
dataSource.getPreparedTransaction( identifier ) ) ) );
return receiver.receive( response );
}
catch ( IOException e )
After Change
try
{
int eventIdentifier = txManager.getEventIdentifier();
Pair<Long, ReadableByteChannel> tx = new Pair<Long, ReadableByteChannel>( -1L,
dataSource.getPreparedTransaction( identifier ) );
Response<Long> response = broker.getMaster().commitSingleResourceTransaction(
receiver.getSlaveContext( eventIdentifier ),
dataSource.getName(), new TransactionStream( Arrays.asList( tx ) ) );